package com.example;

public class CanalCdcUserInsertDelete extends CanalCdcBase {

    @Override
    protected String getJsonFilePath() {
        return "data_simulator/canal_cdc_insert_delete.json";
    }

    public static void main(String[] args) {
        CanalCdcUserInsertDelete canalCdc = new CanalCdcUserInsertDelete();
        canalCdc.processCanalMessages();
    }
} 